Міністерство освіти і науки України
Національний університет „Львівська політехніка” Кафедра ЕОМ
Звіт
до лабораторної роботи № 3-4
з дисципліни
" Системне програмне забезпечення"
Варіант№9
Тема: «Взаємодія між потоками»
Мета: Засвоїти поняття паралельного виконання «потоків» та освоїти засоби їх синхронізації. Здобути навики синхронізації «потоків» при обробці спільних даних та доступу до ресурсів в операційній системі Windows.
Згідно варіанту було розроблено програму в середовищі Visual Studio, що демонструє використання об’єктів синхронізації заданого числа потоків.
Системний виклик
Варіант
9
Critical Section
3
Mutex
Semaphores
2
Лістинг програми: Використання Semaphore :
#include "windows.h"
#include "iostream"
#include "process.h"
using namespace std;
HANDLE hSemaphore;
LONG cMax = 2;
void Test1(void *);
void Test2(void *);
void Test3(void *);
void main()
{
hSemaphore = CreateSemaphore(
NULL,
cMax,
cMax,
NULL
);
if (!hSemaphore == NULL)
{
if (_beginthread(Test1,1024,NULL)==-1)
cout << "Error begin thread " << endl;
if (_beginthread(Test2,1024,NULL)==-1)
cout << "Error begin thread " << endl;
if (_beginthread(Test3,1024,NULL)==-1)
cout << "Error begin thread " << endl;
Sleep(1000);
CloseHandle(hSemaphore);
}
else
cout << "error create semaphore" << endl;
}
void Test1(void *)
{
cout << "Test1 Running" << endl;
DWORD dwWaitResult = 1;
while(dwWaitResult!=WAIT_OBJECT_0)
{
dwWaitResult = WaitForSingleObject(
hSemaphore, // вказівник на семафор
1 // інтервал очікування
);
cout << "Test 1 TIMEOUT" << endl;
}
Sleep(1000);
if (ReleaseSemaphore(
hSemaphore,
1, // зміна лічильника на 1
NULL)
)
cout << " ReleaseSemaphore Ok Test1" << endl;
_endthread();
}
void Test2(void *)
{
cout << "Test2 Running" << endl;
DWORD dwWaitResult = 0;
while(dwWaitResult!=WAIT_OBJECT_0)
{
dwWaitResult = WaitForSingleObject(hSemaphore,1);
cout << "Test 2 TIMEOUT" << endl;
}
Sleep(1000);
if (ReleaseSemaphore(hSemaphore,1,NULL))
cout << " ReleaseSemaphore Ok Test2" << endl;
_endthread();
}
void Test3(void *)
{
cout << "Test2 Running" << endl;
DWORD dwWaitResult = 1;
while(dwWaitResult!=WAIT_OBJECT_0)
{
dwWaitResult = WaitForSingleObject(hSemaphore,1);
cout << "Test 3 TIMEOUT" << endl;
}
if (ReleaseSemaphore(hSemaphore,1,NULL))
cout << " ReleaseSemaphore Ok Test3" << endl;
_endthread();
}
Використання CriticalSection( )
#include<windows.h>
#include<windowsx.h>
#include<process.h>
#include <time.h>
#include<iostream>
#include<conio.h>
using namespace std;
#define DATA_SIZE 256
typedef struct msg_block_tag { /* Message block */
volatile DWORD f_ready, f_stop;
/* ready state flag, stop flag */
volatile DWORD sequence; /* Message block sequence number */
volatile DWORD nCons, nLost;
//time_t timestamp;
CRITICAL_SECTION mguard; /* Guard the message block structure */
DWORD checksum; /* Message contents checksum */
DWORD data[DATA_SIZE]; /* Message Contents */
} MSG_BLOCK;
/* One of the following conditions holds for the message block */
/* 1) !f_ready || f_stop */
/* nothing is assured about the data OR */
/* 2) f_ready && data is valid */
/* && checksum and timestamp are valid */
/* Also, at all times, 0 <= nLost + nCons <= sequence */
/* Single message block, ready to fill with a new message */
MSG_BLOCK mblock = { 0, 0, 0, 0, 0 };
static unsigned __stdcall produce (void *);
static unsigned __stdcall produce1 (void *);
static unsigned __stdcall consume (void *);
void MessageFill (MSG_BLOCK *);
void MessageDisplay (MSG_BLOCK *);
int main ()
{
DWORD Status;
UINT ThId;
HANDLE produce_h, consume_h, produce1_h;
/* Initialize the message block CRITICAL SECTION */
InitializeCriticalSection (&mblock.mguard);
/* Create the two threads */
produce_h = (HANDLE)_beginthreadex (NULL, 0, produce, NULL, 0, &ThId);
if (produce_h == N...
